{
int (*init)(struct starpu_mpi_lb_conf *);
int (*deinit)();
- void (*submitted_task_entry_point)();
- void (*finished_task_entry_point)();
+ void (*submitted_task_entry_point)(struct starpu_task *task);
+ void (*finished_task_entry_point)(void);
/** Name of the load balancing policy. The selection of the load balancer is
* performed through the use of the STARPU_MPI_LB=name environment
}
}
-static void finished_task_heat()
+static void finished_task_heat(void)
{
//fprintf(stderr,"Try to decrement nsubmitted_tasks...");
STARPU_PTHREAD_MUTEX_LOCK(&load_data_mutex);
STARPU_PTHREAD_MUTEX_INIT(&_cache_mutex, NULL);
}
-void _starpu_mpi_cache_shutdown()
+void _starpu_mpi_cache_shutdown(void)
{
if (_starpu_cache_enabled == 0)
return;
extern int _starpu_cache_enabled;
void _starpu_mpi_cache_init(MPI_Comm comm);
-void _starpu_mpi_cache_shutdown();
+void _starpu_mpi_cache_shutdown(void);
void _starpu_mpi_cache_data_init(starpu_data_handle_t data_handle);
void _starpu_mpi_cache_data_clear(starpu_data_handle_t data_handle);
_starpu_mpi_comm_amounts_display(stderr, rank);
_starpu_mpi_comm_amounts_shutdown();
- _starpu_mpi_cache_shutdown(world_size);
+ _starpu_mpi_cache_shutdown();
_mpi_backend._starpu_mpi_backend_shutdown();
*/
cl_int command_ndrange_kernel_submit(command_ndrange_kernel cmd)
{
- starpu_task task = task_create();
+ starpu_task task = task_create(CL_COMMAND_NDRANGE_KERNEL);
task->cl = &cmd->codelet;
task->cl->model = cmd->kernel->perfmodel;
task->cl_arg = cmd;
/*
* Create a StarPU task
*/
-starpu_task task_create()
+starpu_task task_create(cl_command_type typ)
{
struct starpu_task * task;
codelet->where = STARPU_OPENCL | STARPU_CPU | STARPU_CUDA;
- starpu_task task = task_create();
+ starpu_task task = task_create(CL_COMMAND_TASK);
if (num_events != 0)
{
task_depends_on(task, num_events, events);
#include "socl.h"
-starpu_task task_create() STARPU_ATTRIBUTE_MALLOC;
+starpu_task task_create(cl_command_type typ) STARPU_ATTRIBUTE_MALLOC;
void task_dependency_add(starpu_task task, cl_uint num_events, cl_event *events);
void command_completed(cl_command cmd);
};
//function thread
-static void * _starpu_tcpip_thread_pending()
+static void * _starpu_tcpip_thread_pending(void *foo STARPU_ATTRIBUTE_UNUSED)
{
fd_set reads;
fd_set writes;
/**
Dummy implementations of the callbacks
*/
-void _starpu_prof_tool_event_dummy_func()
+static void _starpu_prof_tool_event_dummy_func(struct starpu_prof_tool_info *pti, union starpu_prof_tool_event_info *ptei, struct starpu_prof_tool_api_info *ptai)
{
}